//package main.scala.com.hu.kafka
//
//import main.scala.com.hu.entity.MyKafkaMessage
//import org.apache.flink.api.common.serialization.DeserializationSchema
//import org.apache.flink.api.common.typeinfo.TypeInformation
//
///**
// * @Author: hujianjun
// * @Date: 2021/1/7 21:33
// * @Describe:
// */
//
//class MyKafkaMessageSchema extends DeserializationSchema[MyKafkaMessage] {
//  override def deserialize(bytes: Array[Byte]): MyKafkaMessage = {
//    MyKafkaMessage(String.valueOf(bytes(0)), String.valueOf(bytes(1)), bytes(2))
//  }
//
//  override def isEndOfStream(t: MyKafkaMessage): Boolean = false
//
//  override def getProducedType: TypeInformation[MyKafkaMessage] = {
//    TypeInformation.of(MyKafkaMessage.getClass)
//  }
//}
